//package com.micro.common.service.web.mq.consumer;
//
//import com.micro.framework.starter.common.exception.BusinessException;
//
//import com.micro.framework.starter.rocket.annotation.ConsumeMode;
//import com.micro.framework.starter.rocket.annotation.RocketmqMessageListener;
//import com.micro.framework.starter.rocket.consumer.RocketMQListener;
//import com.micro.framework.starter.rocket.message.ReceivedMessage;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Service;
//
//
//@Slf4j
//@Service
//@RocketmqMessageListener(instanceName = "rocketMQInstance-1",
//        topic = "ybx_test",
//        consumerGroup = "GID_ybx_1",
//        consumeMode = ConsumeMode.ORDERLY)
//public class TradeConsumer implements RocketMQListener {
//    @Override
//    public void onMessage(ReceivedMessage message) {
//        String body = message.getBody();
//        log.info("WsbTradeConsumer-------获取到消费信息：{}", body);
//
//        try{
//
//        }catch (Exception e){
//            log.error("执行失败,触发消息重试",e);
//            throw new BusinessException("执行失败,触发消息重试"+ e.getMessage());
//        }
//    }
//}
